<?php

// Create a document instance 
require 'simple_dom.php';
include 'connection.php';

function replace_class($file_contents) {
    return str_replace('class=""', 'class="prix"', $file_contents);
}

function collectData($chemin_fichier_html,$id_categ,$id_en,$id_ty,$id_prod) {
    
    $html = file_get_html($chemin_fichier_html);
    
    foreach ($html->find('.bgdProduit') as $bgp) {
        $categorie = $bgp->find('h2', 0)->innertext;        
        $query_produit = "INSERT INTO categorie (_id_categorie,libelle) values ($id_categ,'$categorie');";
        if (!mysql_query($query_produit)) {
            //die('Error: ' . mysql_error());
            echo "fuck";
        } else {
            
        }
        
//        $qery_id_categorie = "SELECT _id_categorie FROM categorie where libelle = '$categorie'";
//        $result_cate = mysql_query($qery_id_categorie) or die(mysql_error());
//        $id_cate = mysql_fetch_array($result_cate) or die(mysql_error());
//        $id_categorie = $id_cate['_id_categorie'];
        
        
        $typeprod = $bgp->find('ul li.lev3On', 0)->innertext;
        $query_produit = "INSERT INTO  typeprod (_id_typeprod,_id_categorie,libelle) values ($id_ty,$id_categ,'$typeprod');";
        if (!mysql_query($query_produit)) {
           //die('Error: ' . mysql_error());
            echo "fuck";
        } else {
            
        }
//        mysql_free_result($result_cate);
        

//        $qery_id_typ = "SELECT _id_typeprod FROM typeprod where libelle = '$typeprod'";
//        $result_typ = mysql_query($qery_id_typ) or die(mysql_error());
//        $id_typ = mysql_fetch_array($result_typ) or die(mysql_error());
//        $id_typ = $id_typ['_id_typeprod'];
//        mysql_free_result($result_typ);

        $produit = $html->find('h1', 0)->innertext;
        $val = mysql_real_escape_string($produit);
        $search = array("\t", "\n", "\r");
        $val = str_replace($search, '', $val);     
        $query_produit = "INSERT INTO produit (_id_produit,_id_categorie,_id_typeprod,Libelle) values ($id_prod,$id_categ,$id_ty,'$val');";
        if (!mysql_query($query_produit)) {
           //die('Error: ' . mysql_error());
            echo "fuck";
        } else {
            
        }


        $qery_id_produit = "SELECT _id_produit FROM produit where Libelle = '$val'";
        $result = mysql_query($qery_id_produit) or die(mysql_error());
        $id = mysql_fetch_array($result) or die(mysql_error());
        $id_produit = $id['_id_produit'];

        mysql_free_result($result);

        foreach ($html->find('tbody tr') as $tb) {
            $produit = $tb->find('.imgProduitMdd', 0);
            if (!is_null($produit)) {
                $ens = $tb->find('.imgProduitMdd', 0)->alt;
                //$lien_image_enseigne=$produit->find('.prixMoyen img',0)->src;      
                $query_ens = "INSERT INTO enseigne (_id_enseigne,Nom) values ($id_en,'$ens');";
                if (!mysql_query($query_ens)) {
                    //die('Error: ' . mysql_error());
                } else {
                    
                }
            }
        }

        foreach ($html->find('tbody tr') as $tb) {
            $produit = $tb->find('.imgProduitMdd', 0);
            
            if (!is_null($produit)) {
                $ens = $tb->find('.imgProduitMdd', 0)->alt;
                $qery_id_ens = "SELECT _id_enseigne FROM enseigne where Nom = '$ens'";
                $result = mysql_query($qery_id_ens) or die(mysql_error());
                $id = mysql_fetch_array($result) or die(mysql_error());
                mysql_free_result($result);
                $id_ens = $id['_id_enseigne'];
                $prix_pourri = $tb->find('[headers="header3"]', 0)->innertext;
                $regex = '#([0-9.]+)€#U';
                preg_match($regex, $prix_pourri, $section_prix);
                $prix = $section_prix[1];
                $query_prix = "INSERT INTO prix_produit (_id_produit,_id_enseigne,prix) values ($id_produit,$id_ens,$prix)";
                //echo $query_prix;
                if (!mysql_query($query_prix)) {

                    $query_prix_update = "UPDATE prix_produit SET prix=$prix where _id_produit=$id_produit and _id_enseigne = $id_ens";
                    // echo $query_prix_update;
                    mysql_query($query_prix_update) or die(mysql_error());
                    //die(mysql_error());
                } else {
                    
                }
            }
        }
    }
    //$GLOBALS['cpt'] = $GLOBALS['cpt'] + 1;   
}
$cpt = 0;

$dossier_depart = 'D:/dataTest/';
$fichiers = array();
if (is_dir($dossier_depart)) {
    if ($dh = opendir($dossier_depart)) {
        while (($fic = readdir($dh)) !== false) {
            if (!in_array($fic, array('.', '..')))
                $fichiers[] = $dossier_depart . $fic;
        }
        closedir($dh);
    }
    else
        echo $dossier_depart . ' n\'est pas un repertoire valide!';
}
else
    echo $dossier_depart . ' n\'est pas un repertoire !';

//print_r($fichiers);
sort($fichiers);

//for ($i = 1; $i <= 70; $i++){

for ($i = 1; $i < 2000; $i++){
    echo $i;
    echo $fichiers[$i - 1];
    echo $fichiers[$i];
    collectData($fichiers[$i - 1],$i,$i,$i,$i);
}

//echo $id_categ;
//foreach ($fichiers as $chemin_fichier) {
//    //
//   
//    $id_categ ++;
//    echo $id_categ;
//    $id_en ++;
//    $id_ty ++;
//    $id_prod ++;
//    $cpt ++;
//    collectData($chemin_fichier,$id_categ,$id_en,$id_ty,$id_prod);
//    // $fichierdep = explode("/", $fichiers[$i]);
//    // if (copy($fichiers[$i],'D:/dataMove/'.$fichierdep[2])) {
//    //   unlink($fichiers[$i]);
//    // }
//}
////echo htmlentities(utf8_decode("Mise à jour effectué : ".$cpt));

ECHO 'Fini Kiri Kiri!!!! : '.$cpt;

?>

    